package com.fxkj.cloud.drms.infra.utils;

import com.google.common.util.concurrent.ListenableFuture;

/**
 * 数据处理器
 * @param <T>
 * @param <F>
 */
public interface BufferedRateExecutor<T extends AsyncTask, F extends ListenableFuture> {

    F submit(T task);
}
